package socket.chat;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashSet;
import java.util.Set;

public class Server {
	private ServerSocket server; //建立名字为server的服务器套接字
	private Set<Socket> cs;    //建立Set集合用来储存socket数
	public Server(){      //构造一个Server类的方法
		cs=new HashSet<>();    
		try {
			server = new ServerSocket(8088);//建立server服务器套接字的端口号为：8088
			while(true){     //建立死循环来接收消息
				Socket socket=server.accept(); //接受客户端的请求
				cs.add(socket);  //
				System.out.println(socket.getInetAddress().getHostAddress()+"进来了");
				Receiver rc=new Receiver(socket, cs); //实例化,获取cs中的socket信息
				rc.start(); //调用Receiver中的run（）方法
				}			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	public static void main(String[] args) {
		new Server();  //实例化服务器类
	}
	
}
